const kettle = require('../index.js');

async function main() {
  const list = await kettle.listReader([1, 2, 3]);
  const format = await kettle.formatTransform(o=>o+'f');
  const format1 = await kettle.formatTransform(o=>o+'f==');
  const log = await kettle.logTransform(1);
  const log1 = await kettle.logTransform(2);
  const x = list.pipe(format);
  format.pipe(log);
  format.pipe(log1);
  // x.pipe(log);
  // x.pipe(log1);
}

main()